package com.df.ez_game.server.broker;

public class BrokerTest1 {
    public static void main(String[] args) throws InterruptedException {
        ClusterNode node1 = new ClusterNode();
        node1.setName("node1")
                .setPort(9898);

        ClusterNode node2 = new ClusterNode();
        node2.setName("node2")
                .setPort(9899)
                .getSeedAddress().add("192.168.1.14:9898");

        node1.start();
        System.out.println();
        System.out.println();
        Thread.sleep(2000);
        node2.start();

        System.out.println(1);
    }
}
